import Redis from 'ioredis';
const redis = new Redis();


// 消费者：从队列中获取消息并处理
async function consumeMessages(queueName:string) {
    while (true) {
        try {
            // 从队列左侧弹出一条消息
            const message = await redis.blpop(queueName, 0);// 0 表示无超时，一直阻塞直到有消息可用/10 表示在10秒内阻塞等待消息。

            if (message) {
                // 处理消息的逻辑
                console.log(`Consumed message: ${message}`);
            }
            console.log("处理完成...");
        } catch (error) {
            console.error('Error consuming message:', error);
        }
    }
}

// 例子
const queueName = 'myQueue';



// 消费者处理队列中的消息
consumeMessages(queueName);
